// package com.jungle.boot.mq.consumer;// Demo01Consumer.java
//
// import com.jungle.boot.mq.message.Demo01Message;
// import lombok.extern.slf4j.Slf4j;
// import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
// import org.apache.rocketmq.spring.core.RocketMQListener;
// import org.springframework.stereotype.Component;
//
// @Slf4j
// @Component
// @RocketMQMessageListener(
//         topic = Demo01Message.TOPIC,
//         consumerGroup = "demo01-A-consumer-group-" + Demo01Message.TOPIC
// )
// public class Demo01AConsumer implements RocketMQListener<Demo01Message> {
//
//     @Override
//     public void onMessage(Demo01Message message) {
//         log.info("[Demo01AConsumer==A=onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
//     }
//
// }